f08688a28e6c5c72b6fa6673bf13bceea3a6fc1c,src/org/jgroups/blocks/GroupRequest.java,GroupRequest,viewChange,#View#,331
Before Change
return;
synchronized(rsp_mutex) {
this.members.clear();
this.members.addAll(mbrs);
for(int i=0; i < membership.length; i++) {
mbr=membership[i];
if(!mbrs.contains(mbr)) {
After Change
if(requests == null || requests.size() == 0 || mbrs == null)
return;
synchronized(this.members) {
this.members.clear();
this.members.addAll(mbrs);
}
Map.Entry entry;
Rsp rsp;
boolean modified=false;
synchronized(requests) {
for(Iterator it=requests.entrySet().iterator(); it.hasNext();) {
entry=(Map.Entry)it.next();
mbr=(Address)entry.getKey();
if(!mbrs.contains(mbr)) {
addSuspect(mbr);
rsp=(Rsp)entry.getValue();
rsp.setValue(null);
rsp.setSuspected(true);
modified=true;
}